#include "app_mqtt.h"
#include "log.h"
#include <stdlib.h>
#include <unistd.h>



int mqtt_callback(char *data ,int len)
{
	log_info(" 收到数据: %.*s",len,data);
	return 0;
}

int main(int argc, char const *argv[])
{
	//1 初始化
	int ret=app_mqtt_init();
	if (ret<0)
	{
		 log_error("初始化失败");
	}
	
	// 2 注册数据的后续处理
	app_mqtt_register_recv(mqtt_callback);
	// 3  发送数据
	app_mqtt_send("hello world",11);

	sleep(10000);

	// 4  销毁客户端
	app_mqtt_destroy();

	return 0;
}
